package com.ziroom.crm.mq.core.processor.retry.config;

import com.ziroom.crm.mq.core.config.MqConfig;
import com.ziroom.crm.mq.core.processor.retry.DefaultSendRetryProcessor;
import com.ziroom.crm.mq.core.retry.RetryConst;
import com.ziroom.crm.mq.core.retry.delay.FixedDelayPolicy;
import com.ziroom.crm.mq.core.spi.SpiAlias;

/**
 * 用于解析配置，消费端立即重试，数量策略
 * <p/>
 *
 * @author WeiShaoying
 * @date Created in 2020年09月16日 16:05
 * @since 1.0.0
 */
@SpiAlias(value = RetryConst.DELAY_POLICY_FIXED, group = DefaultSendRetryProcessor.GROUP_SEND)
public class SendFixedDelayPolicy extends FixedDelayPolicy {

    public SendFixedDelayPolicy() {
        super(Integer.parseInt(MqConfig.getConfig(MqConfig.RETRY_SEND_DELAY_PERIOD)));
    }
}
